package com.yungui.kafka.consumer.constant;

/**
 * @author laiaiqin
 * @since 2019/5/24
 */
public class EsConstant {
    public static final String INDEX_TYPE = "_doc";
    public static final String PK_NAME = "id";
    public static final String CP_PK_NAME = "application_id";
    public static final String EVENT_TYPE_DELETE = "DELETE";

    //15秒
    public static final int REJECT_SLEEP = 15000;

    public static final int REJECT_MAX_RETRY_TIMES = 5;

    private EsConstant() {
    }
}
